package com.yc.streaming.common;

/**
 * 常量接口
 * 
 * @author Administrator
 *
 */
public interface Constants {

	/**
	 * 项目配置相关的常量
	 */
	String JDBC_DRIVER = "jdbc.driver";
	String JDBC_DATASOURCE_SIZE = "jdbc.datasource.size";
	String JDBC_URL_PROD = "jdbc.url.prod";
	String JDBC_USER_PROD = "jdbc.user.prod";
	String JDBC_PASSWORD_PROD = "jdbc.password.prod";

	String REDIS_HOST = "redis.host";
	String REDIS_PORT = "redis.port";
	String REDIS_KEY_EXPIRE_TIME = "redis.key.expire";

	// redis 数据库索引值
	String REDIS_ORDERHISTORY_INDEX = "redis.orderHistory.index";
	String REDIS_DISPATCHHISTORY_INDEX = "redis.dispatchHistory.index";
	String REDIS_DISTINCT_INDEX = "redis.distinct.index";
	
	// redis key 
	String REDIS_ORDER_KEY = "redis.order.key";
	String REDIS_DISPATCH_DETAIL_KEY = "redis.dispatch.detail.key";
	String REDIS_DISTINCT_KEY = "redis.distinct.key" ;

	String ORDER_TOPIC = "kafka.order.topic";
	String DISPATCH_DETAIL_TOPIC = "kafka.dispatch_detail_topic";
	String KAFKA_METADATA_BROKER_LIST = "kafka.metadata.broker.list";

	String BATCH_INTERVAL = "batch.interval";

}
